package com.ai.redis.util.thread;

import java.util.Map;
import java.util.Set;

import redis.clients.jedis.JedisPool;
import redis.clients.jedis.Pipeline;

public class PipelineThreadSet extends PipelineThread<Set<String>> { 

	 
	public PipelineThreadSet(JedisPool pool, Map<String, Set<String>> vmap) {
		super(pool, vmap); 
	}
	
	protected void set(Pipeline p, String k) {
		Set<String> t= vmap.get(k);
		String[] dataArray = t.toArray(new String[t.size()]);
		p.sadd(k, dataArray); 
	}
	 
}